from foftact.db.dbutil import pooled_db

# 从连接池获取连接
connection = pooled_db.connection()

if connection.is_connected():
    # Example of fetching data
    select_query = "select * from fund limit 100;"
    funds = fetch_query(connection, select_query)

    for fund in funds:
        print(f'fund : {fund}')